package com.navinfo.tripanalysis.offline.service;

import com.navinfo.tripanalysis.common.pojo.Point;
import org.apache.spark.api.java.JavaPairRDD;
import org.apache.spark.api.java.JavaRDD;

import java.io.Serializable;
import java.util.List;

/**
 * 位置点数据排序分组服务类
 * @author 沈东生
 */
public interface PointSortGroupService extends Serializable{
    JavaPairRDD<Long, List<Point>> sortAndGroup(JavaRDD<Point> pointsRdd);
}
